package com.guchenbo.spark.sql

object SparkJdbcUtils {

  def mysqlTd(): SparkJdbcOption = {
    val sparkJdbcOption = new SparkJdbcOption
    sparkJdbcOption.url = "jdbc:mysql://10.57.16.13:3306/model_manager?useSSL=false"
    sparkJdbcOption.user = "model_paas_manager"
    sparkJdbcOption.password = "Liu_0123456789"
    sparkJdbcOption.driver = "com.mysql.jdbc.Driver"
    sparkJdbcOption
  }


  class SparkJdbcOption {
    var url: String = ""
    var user: String = ""
    var password: String = ""
    var driver: String = ""
    var partitionColumn: String = ""
  }

  class SqlOpt {
    var viewName: String = ""
    var viewSql: String = ""
    var insertSql: String = ""
  }
}
